package com.alibaba.otter.node.etl.load.loader.mq.rabbit.exception;


import com.alibaba.otter.node.etl.load.loader.mq.rabbit.MqConstants;
import com.alibaba.otter.node.etl.load.loader.mq.rabbit.serializer.Serializer;

public class MqSerializeException extends MqPluginException {


    private static final long serialVersionUID = -1757162579567664163L;

    private Class clz;
    private Serializer serializer;

    public MqSerializeException(String msg) {
        super(MqConstants.ERROR_CODE_SERIALIZE, msg);
    }

    public MqSerializeException(String msg, Class clz, Serializer serializer, Throwable cause) {
        super(MqConstants.ERROR_CODE_SERIALIZE, msg, cause);
        this.clz = clz;
        this.serializer = serializer;
    }
}
